package com.java.code.kafka;

/**
 * @author weichuanyuan
 * @e-mail wei.cy@bsoft.com.cn
 * @date 2021/10/19 21:41
 * @package com.java.code.kafka
 * @description
 */
public interface MQConsumer {
    void start();

    void shutdown();

    void subscribe(String var1, MQBusinessHandler var2);

    void unsubscribe(String var1);
}
